kafka producer and consumer example in python